package org.gorson.watermark;

import org.apache.flink.api.common.eventtime.Watermark;
import org.apache.flink.api.common.eventtime.WatermarkGenerator;
import org.apache.flink.api.common.eventtime.WatermarkOutput;
import org.gorson.BO.SensorReadingBO;

public class SensorWatermarkGenerator implements WatermarkGenerator<SensorReadingBO> {
    @Override
    public void onEvent(SensorReadingBO sensorReadingBO, long l, WatermarkOutput watermarkOutput) {
//        watermarkOutput.emitWatermark(new Watermark());
//        sensorReadingBO.timestamp;
    }

    @Override
    public void onPeriodicEmit(WatermarkOutput watermarkOutput) {
//        watermarkOutput.emitWatermark();
    }
}
